//package com.example.springbootdemo;
//
//import com.aliyun.openservices.ons.api.*;
//
//import java.util.Properties;
//
///**
// * @author ：cici
// * @date ：Created in 2019/3/11 14:47
// */
//public class ConsumerTest {
//    public static void main(String[] args) {
//        Properties properties = new Properties();
//        // 您在控制台创建的 Group ID
//        properties.put(PropertyKeyConst.GROUP_ID, "GID_test");
//        // 鉴权用 AccessKey，在阿里云服务器管理控制台创建
//        properties.put(PropertyKeyConst.AccessKey, "LTAI5yJLMvPnoECQ");
//        // 鉴权用 SecretKey，在阿里云服务器管理控制台创建
//        properties.put(PropertyKeyConst.SecretKey, "sr5MjGlDqEbYn69NPioqvbF1LQRvb6");
//        // 设置 TCP 接入域名，进入控制台的实例管理页面，在页面上方选择实例后，在实例信息中的“获取接入点信息”区域查看
//        properties.put(PropertyKeyConst.NAMESRV_ADDR,"http://MQ_INST_1871706301460146_BaanXYCQ.mq-internet-access.mq-internet.aliyuncs.com:80");
//        Consumer consumer = ONSFactory.createConsumer(properties);
//        consumer.subscribe("testMQ", "*", new MessageListener() {
//            public Action consume(Message message, ConsumeContext context) {
//                System.out.println("Receive: " + message);
//                return Action.CommitMessage;
//            }
//        });
//        consumer.start();
//        System.out.println("Consumer Started");
//    }
//}
